//package com.turing.post.test;
//
//import com.ibm.mq.MQC;
//import com.ibm.mq.MQEnvironment;
//import com.ibm.mq.MQException;
//import com.ibm.mq.MQGetMessageOptions;
//import com.ibm.mq.MQMessage;
//import com.ibm.mq.MQQueue;
//import com.ibm.mq.MQQueueManager;
//
//public class MQGetMessage {
//
//	/**
//	 * @param args
//	 */
//	public static void main(String[] args) {
//
//		String hostName = "192.168.1.205";// //主机名，也可以是IP
//		int port = 1414;
//		String channel = "SYSTEM.DEF.SVRCONN"; // //通道
//		String mqManager = "DFTMQ"; // 队列管理器
//		String mqQname = "YXBMQ"; // 队列
//		String msgText = "";
//		try {
//			MQEnvironment.hostname = hostName;
//			MQEnvironment.channel = channel;
//			MQEnvironment.port = port;
//			MQEnvironment.CCSID = 1381;
//			MQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY,
//					MQC.TRANSPORT_MQSERIES);
//			MQQueueManager qMgr = new MQQueueManager(mqManager);
//			int openOptions = MQC.MQOO_INPUT_AS_Q_DEF
//					| MQC.MQGMO_FAIL_IF_QUIESCING;
//			MQQueue qName = qMgr.accessQueue(mqQname, openOptions, null, null,
//					null);
//			MQMessage retrievedMessage = new MQMessage();
//			MQGetMessageOptions gmo = new MQGetMessageOptions();
//			gmo.options = MQC.MQGMO_WAIT | MQC.MQGMO_FAIL_IF_QUIESCING
//					| MQC.MQGMO_NO_SYNCPOINT;
//			gmo.waitInterval = 10000;
//			qName.get(retrievedMessage, gmo);
//			msgText = retrievedMessage.readUTF();
//			//msgText = retrievedMessage.readLine();
//			System.out.println("I received a message is===" + msgText);
//			qName.close();
//			qMgr.disconnect();
//		} catch (MQException e) {
//			e.printStackTrace();
//		} catch (java.io.IOException e) {
//			e.printStackTrace();
//		}
//
//	}
//
//}
